package org.onvivals.app.websocket;//package org.onvivals.app.websocket;
//
//import org.springframework.stereotype.Component;
//import org.tio.core.ChannelContext;
//import org.tio.core.Tio;
//import org.tio.http.common.HttpRequest;
//import org.tio.http.common.HttpResponse;
//import org.tio.websocket.common.WsRequest;
//import org.tio.websocket.server.handler.IWsMsgHandler;
//
//@Component
//public class MyWebSocketMsgHandler implements IWsMsgHandler {
//    /**
//     * 握手
//     *
//     * @param httpRequest    http请求
//     * @param httpResponse   http响应
//     * @param channelContext 渠道上下文
//     * @return {@link HttpResponse}
//     */
//    @Override
//    public HttpResponse handshake(HttpRequest httpRequest, HttpResponse httpResponse, ChannelContext channelContext) {
//        String token = httpRequest.getParam("deviceId");
//        channelContext.setToken(token);
//        Tio.bindUser(channelContext, "1");
//        System.out.println("handshake握手方法");
//        return httpResponse;
//    }
//
//    /**
//     * 握手后打开
//     *
//     * @param httpRequest    http请求
//     * @param httpResponse   http响应
//     * @param channelContext 渠道上下文
//     */
//    @Override
//    public void onAfterHandshaked(HttpRequest httpRequest, HttpResponse httpResponse, ChannelContext channelContext) {
//        System.out.println("onAfterHandshaked握手后打开的");
//    }
//
//    /**
//     * 在字节上
//     *
//     * @param wsRequest      ws请求
//     * @param bytes          字节
//     * @param channelContext 渠道上下文
//     * @return {@link Object}
//     */
//    @Override
//    public Object onBytes(WsRequest wsRequest, byte[] bytes, ChannelContext channelContext) {
//        System.out.println("onBytes方法");
//        return null;
//    }
//
//    /**
//     * 关闭
//     *
//     * @param wsRequest      ws请求
//     * @param bytes          字节
//     * @param channelContext 渠道上下文
//     * @return {@link Object}
//     */
//    @Override
//    public Object onClose(WsRequest wsRequest, byte[] bytes, ChannelContext channelContext) {
//        System.out.println("onClose关闭方法");
//        return null;
//    }
//
//    /**
//     * 在文本上
//     *
//     * @param wsRequest      ws请求
//     * @param channelContext 渠道上下文
//     * @param message        信息
//     * @return {@link Object}
//     */
//    @Override
//    public Object onText(WsRequest wsRequest, String message, ChannelContext channelContext) {
//        if ("心跳包".equals(message)) {
//            return null;
//        }
//        return null;
//    }
//}
